//package com.lzx.adx.report.job;
//
//import cn.hutool.core.collection.CollectionUtil;
//import cn.hutool.core.net.URLDecoder;
//import cn.hutool.core.util.URLUtil;
//import cn.hutool.http.HttpRequest;
//import cn.hutool.http.HttpUtil;
//import com.alibaba.fastjson.JSONObject;
//import com.lzs.adx.commmon.redis.RedisUtils;
//import com.lzx.adx.report.constant.RedisKeyConstant;
//import com.lzx.adx.report.dto.ReportDTO;
//import com.lzx.adx.report.enums.LianMengCovertXmlyEventTypeEnums;
//import com.lzx.adx.report.service.ReportService;
//import com.lzx.adx.report.util.UrlParamsReplacer;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.scheduling.annotation.EnableScheduling;
//import org.springframework.scheduling.annotation.Scheduled;
//import org.springframework.stereotype.Component;
//
//import java.nio.charset.StandardCharsets;
//import java.util.Date;
//import java.util.HashMap;
//import java.util.List;
//import java.util.Map;
//
///**
// * 西马拉雅-快手极速 回传异步任务
// */
//@Component
//@EnableScheduling
//@Slf4j
//public class XmlyYsJob {
//
//
//    @Autowired
//    private ReportService reportService;
//
//    @Autowired
//    private RedisUtils redisUtils;
//
//    /**
//     * 趣头条-西瓜视频
//     */
//    @Scheduled(cron = "0 */10 * ? * *")
//    public void reportEvent(){
//        log.info("进行西马拉雅-快手极速-上报处理-begin");
//        Map<String, Object> stringObjectMap = redisUtils.hgetAll(RedisKeyConstant.XMLY_KSJS);
//        int size = stringObjectMap.size();
//        log.info("进行西马拉雅-快手极速-本次需要处理的数量为{}",size);
//        if(CollectionUtil.isNotEmpty(stringObjectMap)){
//            //
//            for(Map.Entry<String,Object> ev:stringObjectMap.entrySet()){
//                try {
//                    Object value = ev.getValue();
//                    log.info("目前正在执行{}",value);
//                    long eventTime = System.currentTimeMillis();
//                    callBackUrl(String.valueOf(value),"0",String.valueOf(eventTime));
//                }catch (Exception e){
//                    log.error("西马拉雅-快手极速-出现了异常{}",ev.getValue());
//                }
//
//            }
//        }
//        log.info("进行西马拉雅-快手极速-上报处理-end");
//    }
//
//
//
//    public void callBackUrl(String requestId, String event_type, String event_time)  {
//        log.info("接收了西马拉雅-有柿回调信息，请求流水号{},回调类型为{}，回调时间{}",requestId,event_type,event_time);
//
//        //1.把转换结果更新到数据库
//        Map<String,Object> params=new HashMap<>();
//        params.put("bizRequestId",requestId);
//        List<ReportDTO> list = reportService.list(params);
//        ReportDTO reportDTO = list.get(0);;
//        reportDTO.setResultType(event_type);
//        reportDTO.setResultTime(event_time);
//        reportDTO.setUpdateTime(new Date());
//        reportService.updateData(reportDTO);
//
//
//        //2.从缓存加载配置
//        String finalResultUrl = UrlParamsReplacer.replaceTypeParameter(reportDTO.getCallback(), "act");
//        log.info("西马拉雅-快手极速上报回传结果，完整的URl{}",finalResultUrl);
//
//        HttpRequest body = HttpUtil.createGet(finalResultUrl);
//        String result = body.execute().body();
//        log.info("dsp账户ID{}，接收西马拉雅-快手极速上报转换响应的结果为{}",reportDTO.getDspId(),result);
//    }
//}
